380273826d05913d4b80b73e0db2ea49711b17c7,test/pig/org/apache/cassandra/pig/ThriftColumnFamilyDataTypeTest.java,ThriftColumnFamilyDataTypeTest,testCassandraStorageDataType,#,127
Before Change
//col_uft8: (name: chararray,value: chararray),
//col_uuid: (name: chararray,value: chararray),
//columns: {(name: chararray,value: chararray)}}
Iterator<Tuple> it = pig.openIterator("rows");
if (it.hasNext()) {
Tuple t = it.next();
Assert.assertEquals(t.get(0), "foo");
Tuple column = (Tuple) t.get(1);
Assert.assertEquals(column.get(1), "ascii");
column = (Tuple) t.get(2);
Assert.assertEquals(column.get(1), false);
column = (Tuple) t.get(3);
Assert.assertEquals(column.get(1), new DataByteArray(Hex.hexToBytes("DEADBEEF")));
column = (Tuple) t.get(4);
Assert.assertEquals(column.get(1), 1296705900000L);
column = (Tuple) t.get(5);
Assert.assertEquals(column.get(1), "23.345");
column = (Tuple) t.get(6);
Assert.assertEquals(column.get(1), 2.7182818284590451d);
column = (Tuple) t.get(7);
Assert.assertEquals(column.get(1), 23.45f);
column = (Tuple) t.get(8);
Assert.assertEquals(column.get(1), "127.0.0.1");
column = (Tuple) t.get(9);
Assert.assertEquals(column.get(1), 23);
column = (Tuple) t.get(10);
Assert.assertEquals(column.get(1), 12345);
column = (Tuple) t.get(11);
Assert.assertEquals(column.get(1), new DataByteArray((TimeUUIDType.instance.fromString("e23f450f-53a6-11e2-7f7f-7f7f7f7f7f77").array())));
column = (Tuple) t.get(12);
Assert.assertEquals(column.get(1), 12345678L);
column = (Tuple) t.get(13);
Assert.assertEquals(column.get(1), new DataByteArray((TimeUUIDType.instance.fromString("e23f450f-53a6-11e2-7f7f-7f7f7f7f7f7f").array())));
column = (Tuple) t.get(14);
After Change
NoSuchFieldException, IllegalAccessException, InstantiationException
{
pig.registerQuery("rows = LOAD 'cassandra://thrift_ks/some_app?" + defaultParameters + "' USING CassandraStorage();");
Tuple t = pig.openIterator("rows").next();
// key
assertEquals("foo", t.get(0));
// col_ascii
Tuple column = (Tuple) t.get(1);
assertEquals("ascii", column.get(1));
// col_bigint
column = (Tuple) t.get(2);
assertEquals(12345678L, column.get(1));
// col_blob
column = (Tuple) t.get(3);
assertEquals(new DataByteArray(Hex.hexToBytes("DEADBEEF")), column.get(1));
// col_boolean
column = (Tuple) t.get(4);
assertEquals(false, column.get(1));
// col_decimal
column = (Tuple) t.get(5);
assertEquals("23.345", column.get(1));
// col_double
column = (Tuple) t.get(6);
assertEquals(2.7182818284590451d, column.get(1));
// col_float
column = (Tuple) t.get(7);
assertEquals(23.45f, column.get(1));
// col_inet
column = (Tuple) t.get(8);
assertEquals("127.0.0.1", column.get(1));
// col_int
column = (Tuple) t.get(9);
assertEquals(23, column.get(1));
// col_text
column = (Tuple) t.get(10);
assertEquals("hello", column.get(1));
// col_timestamp
column = (Tuple) t.get(11);
assertEquals(1296705900000L, column.get(1));
// col_timeuuid
column = (Tuple) t.get(12);
assertEquals(new DataByteArray((TimeUUIDType.instance.fromString("e23f450f-53a6-11e2-7f7f-7f7f7f7f7f7f").array())), column.get(1));
// col_uuid
column = (Tuple) t.get(13);
assertEquals(new DataByteArray((UUIDType.instance.fromString("550e8400-e29b-41d4-a716-446655440000").array())), column.get(1));
// col_varint
column = (Tuple) t.get(14);
assertEquals(12345, column.get(1));
pig.registerQuery("cc_rows = LOAD 'cassandra://thrift_ks/cc?" + defaultParameters + "' USING CassandraStorage();");
t = pig.openIterator("cc_rows").next();